package WindowAndWatermark

import org.apache.flink.streaming.api.TimeCharacteristic
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment

class EventTimeTest {
  def main(args: Array[String]): Unit = {
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    //设置并行度
    env.setParallelism(1)
    //时间语义(TimeEvent)
    env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
  }
}
